//
// Created by denglibin on 19-10-24.
//
/**
 *进程间使用互斥量完成同步
 **/

#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <string.h>
#include <pthread.h>
#include <sys/mman.h>
#include <sys/wait.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <fcntl.h>

struct mt{
    int num;
    pthread_mutex_t mutex;
    pthread_mutexattr_t mutexattr;
};

static int main_(void){
    int fd, i;
    struct mt * mm;
    pid_t  pid;
    fd = open("mt_test", O_CREAT | O_RDWR, 0644);
    ftruncate(fd, sizeof(*mm));
    // 内存映射 实现父子进程进程共享
    mm = mmap(NULL, sizeof(*mm), PROT_READ | PROT_WRITE, MAP_SHARED, fd, 0);
    close(fd);
    unlink("mt_test");
    memset(mm, 0, sizeof(*mm));

    pthread_mutexattr_init(& mm->mutexattr); // 初始化互斥量属性
    pthread_mutexattr_setpshared(& mm->mutexattr, PTHREAD_PROCESS_SHARED); // 进程间共享

    // 使用互斥量属性初始化互斥量
    pthread_mutex_init(& mm->mutex, & mm->mutexattr);

    pid = fork();
    if(pid == 0)// 子进程
    {
        for(i = 0; i < 10; i++){
            pthread_mutex_lock(& mm->mutex);//加锁
            mm->num ++;
            printf("child -- num -- %d\n", mm->num);
            pthread_mutex_unlock(& mm->mutex); //释放锁
            sleep(1);
        }
    }else{ // 父进程
        for(i = 0; i < 10; i++){
            pthread_mutex_lock(& mm->mutex);//加锁
            mm->num += 2;
            printf("parent -- num -- %d\n", mm->num);
            pthread_mutex_unlock(& mm->mutex); //释放锁
            sleep(1);
        }
    }
    return 0;
}